package com.ods.mq.db.dto;

import lombok.Data;
import lombok.extern.slf4j.Slf4j;

/**
 * @author YuanX kafka数据传输模型
 * @version 1.0
 * @date 2021/10/20
 */
@Slf4j
@Data
public class KafkaDTO {

    private String id;
    private String name;
    //系统topic
    private boolean isInternal;
    //分区数
    private Integer partition = 1;
    //副本数
    private Integer replica = 1;
    private String message;
    //消息是否批量发送
    private Boolean batch = false;
    //kafka地址
    private String broker;
}
